package com.howso.cloud.kafka.listener;

import com.howso.cloud.kafka.dto.KafkaConfigDTO;

/**
 * <p>kafka工厂初始化时调用，用于修改kafka配置</p>
 *
 */
public interface KafkaInitListener {

    /**
     * <p>更新kafka配置</p>
     *
     * @param config
     **/
    KafkaConfigDTO updateConfig(KafkaConfigDTO config);
}
